Apache ActiveMQ ™ -- XBean XML Reference 5.0
Using ActiveMQ > Xml Reference > XBean XML Reference 5.0
Elements By Type
The org.apache.activemq.broker.TransportConnector Type Implementations
The org.apache.activemq.network.jms.InboundQueueBridge Type Implementations
Create an Inbound Queue Bridge
The org.apache.activemq.network.NetworkConnector Type Implementations
class to create dynamic network connectors listed in an directory server using the LDAP v3 protocol as defined in RFC 2251, the entries listed in the directory server must implement the ipHost and ipService objectClasses as defined in RFC 2307.
A network connector which uses some kind of multicast-like transport that communicates with potentially many remote brokers over a single logical {@link Transport} instance such as when using multicast. This implementation does not depend on multicast at all; any other group based transport could be used.
A network connector which uses a discovery agent to detect the remote brokers available and setup a connection to each available remote broker
The org.apache.activemq.broker.BrokerService Type Implementations
An ActiveMQ Message Broker. It consists of a number of transport connectors, network connectors and a bunch of properties which can be used to configure the broker as its lazily created.
The org.apache.activemq.usage.TempUsage Type Implementations
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
The org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy Type Implementations
Pending messages
Pending messages held
The org.apache.activemq.usage.MemoryUsage Type Implementations
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
The org.apache.activemq.broker.BrokerPlugin Type Implementations
An authorization plugin where each operation on a destination is checked against an authorizationMap
A DOT file creator plugin which creates a DOT file showing the current connections
A DOT file creator plugin which creates a DOT file showing the current topic & queue hierarchies.
Provides a JAAS based authentication plugin
Provides a JAAS based SSL certificate authentication plugin
A simple Broker interceptor which allows you to enable/disable logging.
A Broker interceptor which allows you to trace all operations to a Multicast socket.
Provides a simple authentication plugin
A Broker interceptor which updates a JMS Client's timestamp on the message with a broker timestamp. Useful when the clocks on client machines are known to not be correct and you can only trust the time set on the broker machines. Enabling this plugin will break JMS compliance since the timestamp that the producer sees on the messages after as send() will be different from the timestamp the consumer will observe when he receives the message. This plugin is not enabled in the default ActiveMQ configuration.
A Broker interceptor which allows you to trace all operations to a UDP socket.
The org.apache.activemq.store.jdbc.JDBCAdapter Type Implementations
Axion specific Adapter. Axion does not seem to support ALTER statements or sub-selects. This means: - We cannot auto upgrade the schema was we roll out new versions of ActiveMQ - We cannot delete durable sub messages that have be acknowledged by all consumers.
This JDBCAdapter inserts and extracts BLOB data using the getBlob()/setBlob() operations. This is a little more involved since to insert a blob you have to: 1: insert empty blob. 2: select the blob 3: finally update the blob with data value. The databases/JDBC drivers that use this adapter are:
This JDBCAdapter inserts and extracts BLOB data using the setBytes()/getBytes() operations. The databases/JDBC drivers that use this adapter are:
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
sub-classing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations.
The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations.
The databases/JDBC drivers that use this adapter are:
Provides JDBCAdapter since that uses IMAGE datatype to hold binary data. The databases/JDBC drivers that use this adapter are:
- Sybase
- MS SQL
JDBC Adapter for Informix database. Because Informix database restricts length of composite primary keys, length of container name field and subscription id field must be reduced to 150 characters. Therefore be sure not to use longer names for container name and subscription id than 150 characters.
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
Subclassing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations.
The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations.
The databases/JDBC drivers that use this adapter are:
This JDBCAdapter inserts and extracts BLOB data using the setBinaryStream()/getBinaryStream() operations. The databases/JDBC drivers that use this adapter are:
- Axion
The org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy Type Implementations
Pending
Pending messages
Pending messages
The javax.jms.TopicConnectionFactory Type Implementations
A Spring enhanced connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
A Spring enhanced XA connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
The org.apache.activemq.broker.region.virtual.VirtualDestination Type Implementations
Represents a virtual queue which forwards to a number of other destinations.
Represents a virtual topic which forwards to a number of other destinations.
Creates Virtual Topics using a prefix and postfix. The virtual destination creates a wildcard that is then used to look up all active queue subscriptions which match.
The org.apache.activemq.broker.region.policy.PolicyMap Type Implementations
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies.
The org.apache.activemq.usage.UsageCapacity Type Implementations
Identify if a limit has been reached
Identify if a limit has been reached
The org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy Type Implementations
This PendingMessageLimitStrategy is configured to a constant value for all subscriptions.
This PendingMessageLimitStrategy sets the maximum pending message limit value to be a multiplier of the prefetch limit of the subscription.
The org.apache.activemq.usage.SystemUsage Type Implementations
Holder for Usage instances for memory, store and temp files Main use case is manage memory usage.
The javax.jms.Destination Type Implementations
An ActiveMQ Queue
An ActiveMQ Topic
The org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy Type Implementations
This implementation of {@link SubscriptionRecoveryPolicy} will keep a fixed count of last messages.
This implementation of {@link SubscriptionRecoveryPolicy} will keep a fixed amount of memory available in RAM for message history which is evicted in time order.
This implementation of {@link SubscriptionRecoveryPolicy} will only keep the last message.
This SubscriptionRecoveryPolicy disable recovery of messages.
This implementation of {@link SubscriptionRecoveryPolicy} will perform a user specific query mechanism to load any messages they may have missed.
This implementation of {@link SubscriptionRecoveryPolicy} will keep a timed buffer of messages around in memory and use that to recover new subscriptions.
The javax.jms.QueueConnectionFactory Type Implementations
A Spring enhanced connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
A Spring enhanced XA connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
The org.apache.activemq.broker.jmx.ManagementContext Type Implementations
A Flow provides different dispatch policies within the NMR
The org.apache.activemq.store.jdbc.Statements Type Implementations
The org.apache.activemq.store.PersistenceAdapterFactory Type Implementations
An implementation of {@link PersistenceAdapterFactory}
Creates a default persistence model using the Journal and JDBC
The org.apache.activemq.security.AuthorizationEntry Type Implementations
Represents an entry in a {@link DefaultAuthorizationMap} for assigning different operations (read, write, admin) of user roles to a specific destination or a hierarchical wildcard area of destinations.
Represents an entry in a {@link DefaultAuthorizationMap} for assigning different operations (read, write, admin) of user roles to a temporary destination
The org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy Type Implementations
Pending messages for durable subscribers
Pending messages for a durable
Pending
The org.apache.activemq.broker.region.group.MessageGroupMapFactory Type Implementations
A factory to create instances of {@link SimpleMessageGroupMap} when implementing the Message Groups functionality.
A factory to create instances of {@link SimpleMessageGroupMap} when implementing the Message Groups functionality.
The org.apache.activemq.usage.StoreUsage Type Implementations
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
The org.apache.activemq.broker.region.policy.DeadLetterStrategy Type Implementations
A {@link DeadLetterStrategy} where each destination has its own individual DLQ using the subject naming hierarchy.
A default implementation of {@link DeadLetterStrategy} which uses a constant destination.
The javax.jms.Topic Type Implementations
An ActiveMQ Topic
The org.apache.activemq.ActiveMQPrefetchPolicy Type Implementations
Defines the prefetch message policies for different types of consumers
The org.apache.activemq.broker.Broker Type Implementations
A simple Broker interceptor which allows you to enable/disable logging.
A Broker interceptor which allows you to trace all operations to a Multicast socket.
A Broker interceptor which updates a JMS Client's timestamp on the message with a broker timestamp. Useful when the clocks on client machines are known to not be correct and you can only trust the time set on the broker machines. Enabling this plugin will break JMS compliance since the timestamp that the producer sees on the messages after as send() will be different from the timestamp the consumer will observe when he receives the message. This plugin is not enabled in the default ActiveMQ configuration.
A Broker interceptor which allows you to trace all operations to a UDP socket.
The org.apache.activemq.store.PersistenceAdapter Type Implementations
An implementation of {@link PersistenceAdapter} designed for use with a {@link Journal} and then check pointing asynchronously on a timeout with some other long term persistent storage.
A {@link PersistenceAdapter} implementation using JDBC for persistence storage. This persistence adapter will correctly remember prepared XA transactions, but it will not keep track of local transaction commits so that operations performed against the Message store are done as a single uow.
An implementation of {@link PersistenceAdapter} designed for use with a {@link Journal} and then check pointing asynchronously on a timeout with some other long term persistent storage.
The org.apache.activemq.broker.region.policy.PolicyEntry Type Implementations
Represents an entry in a {@link PolicyMap} for assigning policies to a specific destination or a hierarchical wildcard area of destinations.
The org.apache.activemq.network.DemandForwardingBridgeSupport Type Implementations
A demand forwarding bridge which works with multicast style transports where a single Transport could be communicating with multiple remote brokers
Forwards messages from the local broker to the remote broker based on demand.
The org.apache.activemq.network.jms.OutboundQueueBridge Type Implementations
Create an Outbound Queue Bridge
The org.apache.activemq.store.jdbc.JDBCPersistenceAdapter Type Implementations
A {@link PersistenceAdapter} implementation using JDBC for persistence storage. This persistence adapter will correctly remember prepared XA transactions, but it will not keep track of local transaction commits so that operations performed against the Message store are done as a single uow.
The org.apache.activemq.command.ActiveMQDestination Type Implementations
An ActiveMQ Queue
An ActiveMQ Topic
The org.apache.activemq.network.jms.InboundTopicBridge Type Implementations
Create an Inbound Topic Bridge
The org.apache.activemq.network.jms.JmsConnector Type Implementations
A Bridge to other JMS Queue providers
A Bridge to other JMS Topic providers
The org.apache.activemq.RedeliveryPolicy Type Implementations
Configuration options used to control how messages are re-delivered when they are rolled back.
The org.apache.activemq.security.AuthorizationMap Type Implementations
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies. Each entry in the map represents the authorization ACLs for each operation.
An {@link AuthorizationMap} which uses LDAP
An AuthorizationMap which is configured with individual DestinationMaps for each operation.
The org.apache.activemq.security.TempDestinationAuthorizationEntry Type Implementations
Represents an entry in a {@link DefaultAuthorizationMap} for assigning different operations (read, write, admin) of user roles to a temporary destination
The org.apache.activemq.broker.region.policy.DispatchPolicy Type Implementations
Simple dispatch policy that sends a message to every subscription that matches the message.
Simple dispatch policy that sends a message to every subscription that matches the message.
Dispatch policy that causes every subscription to see messages in the same order.
The javax.jms.ConnectionFactory Type Implementations
A Spring enhanced connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
A Spring enhanced XA connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
The javax.jms.Queue Type Implementations
An ActiveMQ Queue
The org.apache.activemq.broker.region.policy.MessageEvictionStrategy Type Implementations
An eviction strategy which evicts the oldest message first (which is the default).
An eviction strategy which evicts the oldest message with the lowest priority first.
The org.apache.activemq.Service Type Implementations
An ActiveMQ Message Broker. It consists of a number of transport connectors, network connectors and a bunch of properties which can be used to configure the broker as its lazily created.
An agent which listens to commands on a JMS destination
Forwards all messages from the local broker to the remote broker.
Create an Inbound Queue Bridge
Create an Inbound Topic Bridge
A Bridge to other JMS Queue providers
A Bridge to other JMS Topic providers
class to create dynamic network connectors listed in an directory server using the LDAP v3 protocol as defined in RFC 2251, the entries listed in the directory server must implement the ipHost and ipService objectClasses as defined in RFC 2307.
A Flow provides different dispatch policies within the NMR
Connects a Slave Broker to a Master when using Master Slave for High Availability of messages.
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
A network connector which uses some kind of multicast-like transport that communicates with potentially many remote brokers over a single logical {@link Transport} instance such as when using multicast. This implementation does not depend on multicast at all; any other group based transport could be used.
A network connector which uses a discovery agent to detect the remote brokers available and setup a connection to each available remote broker
Create an Outbound Queue Bridge
Create an Outbound Topic Bridge
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
Holder for Usage instances for memory, store and temp files Main use case is manage memory usage.
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
The org.apache.activemq.network.jms.JmsMesageConvertor Type Implementations
Converts Message from one JMS to another
The org.apache.activemq.network.jms.OutboundTopicBridge Type Implementations
Create an Outbound Topic Bridge
The org.apache.activemq.broker.region.DestinationInterceptor Type Implementations
Creates Mirrored Queue using a prefix and postfix to define the topic name on which to mirror the queue to.
Implements Virtual Topics.
The org.apache.activemq.filter.DestinationMap Type Implementations
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies. Each entry in the map represents the authorization ACLs for each operation.
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies.
The org.apache.activemq.network.NetworkBridgeConfiguration Type Implementations
class to create dynamic network connectors listed in an directory server using the LDAP v3 protocol as defined in RFC 2251, the entries listed in the directory server must implement the ipHost and ipService objectClasses as defined in RFC 2307.
A network connector which uses some kind of multicast-like transport that communicates with potentially many remote brokers over a single logical {@link Transport} instance such as when using multicast. This implementation does not depend on multicast at all; any other group based transport could be used.
A network connector which uses a discovery agent to detect the remote brokers available and setup a connection to each available remote broker
The
An implementation of {@link PersistenceAdapter} designed for use with a {@link Journal} and then check pointing asynchronously on a timeout with some other long term persistent storage.
Properties
Property Name
Type
Description
archiveDataLogs
boolean
asyncDataManager
org.apache.activemq.kaha.impl.async.AsyncDataManager
brokerName
java.lang.String
brokerService
org.apache.activemq.broker.BrokerService
checkpointInterval
long
cleanupInterval
long
directory
java.io.File
directoryArchive
java.io.File
indexBinSize
int
indexKeySize
int
indexPageSize
int
When set using XBean, you can use values such as: "20 mb", "1024 kb", or "1 gb"
maxCheckpointMessageAddSize
int
When set using XBean, you can use values such as: "20 mb", "1024 kb", or "1 gb"
maxFileLength
int
When set using XBean, you can use values such as: "20 mb", "1024 kb", or "1 gb"
persistentIndex
boolean
referenceStoreAdapter
org.apache.activemq.store.ReferenceStoreAdapter
syncOnWrite
boolean
taskRunnerFactory
org.apache.activemq.thread.TaskRunnerFactory
usageManager
org.apache.activemq.usage.SystemUsage
useNio
boolean
wireFormat
org.apache.activemq.wireformat.WireFormat
The
An implementation of {@link PersistenceAdapterFactory}
Properties
Property Name
Type
Description
brokerName
java.lang.String
dataDirectory
java.io.File
journalThreadPriority
int
maxFileLength
int
persistentIndex
boolean
referenceStoreAdapter
org.apache.activemq.store.ReferenceStoreAdapter
syncOnWrite
boolean
taskRunnerFactory
org.apache.activemq.thread.TaskRunnerFactory
useNio
boolean
The
A helper object used to configure simple authentiaction plugin
Properties
Property Name
Type
Description
groups
java.lang.String
password
java.lang.String
username
java.lang.String
The
Represents an entry in a {@link DefaultAuthorizationMap} for assigning different operations (read, write, admin) of user roles to a specific destination or a hierarchical wildcard area of destinations.
Properties
Property Name
Type
Description
admin
java.lang.String
adminACLs
(java.lang.Object)*
destination
org.apache.activemq.command.ActiveMQDestination
groupClass
java.lang.String
queue
java.lang.String
A helper method to set the destination from a configuration file
read
java.lang.String
readACLs
(java.lang.Object)*
topic
java.lang.String
A helper method to set the destination from a configuration file
write
java.lang.String
writeACLs
(java.lang.Object)*
The
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies. Each entry in the map represents the authorization ACLs for each operation.
Properties
Property Name
Type
Description
authorizationEntries
(java.lang.Object)*
Sets the individual entries on the authorization map
defaultEntry
org.apache.activemq.security.AuthorizationEntry
entries
(java.lang.Object)*
A helper method to allow the destination map to be populated from a dependency injection framework such as Spring
tempDestinationAuthorizationEntry
org.apache.activemq.security.TempDestinationAuthorizationEntry
The
An authorization plugin where each operation on a destination is checked against an authorizationMap
Properties
Property Name
Type
Description
map
org.apache.activemq.security.AuthorizationMap
The
Axion specific Adapter. Axion does not seem to support ALTER statements or sub-selects. This means: - We cannot auto upgrade the schema was we roll out new versions of ActiveMQ - We cannot delete durable sub messages that have be acknowledged by all consumers.
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
This JDBCAdapter inserts and extracts BLOB data using the getBlob()/setBlob() operations. This is a little more involved since to insert a blob you have to: 1: insert empty blob. 2: select the blob 3: finally update the blob with data value. The databases/JDBC drivers that use this adapter are:
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
An ActiveMQ Message Broker. It consists of a number of transport connectors, network connectors and a bunch of properties which can be used to configure the broker as its lazily created.
Properties
Property Name
Type
Description
adminView
org.apache.activemq.broker.jmx.BrokerView
Returns the administration view of the broker; used to create and destroy resources such as queues and topics. Note this method returns null if JMX is disabled.
advisorySupport
boolean
Allows the support of advisory messages to be disabled for performance reasons.
brokerName
java.lang.String
Sets the name of this broker; which must be unique in the network
brokerObjectName
javax.management.ObjectName
Sets the JMX ObjectName for this broker
clustered
boolean
consumerSystemUsage
org.apache.activemq.usage.SystemUsage
dataDirectory
java.lang.String
Sets the directory in which the data files will be stored by default for the JDBC and Journal persistence adaptors.
dataDirectoryFile
java.io.File
Sets the directory in which the data files will be stored by default for the JDBC and Journal persistence adaptors.
deleteAllMessagesOnStartup
boolean
Sets whether or not all messages are deleted on startup - mostly only useful for testing.
destinationFactory
org.apache.activemq.broker.region.DestinationFactory
destinationInterceptors
(org.apache.activemq.broker.region.DestinationInterceptor)*
Sets the destination interceptors to use
destinationPolicy
org.apache.activemq.broker.region.policy.PolicyMap
Sets the destination specific policies available either for exact destinations or for wildcard areas of destinations.
destinations
(org.apache.activemq.command.ActiveMQDestination)*
Sets the destinations which should be loaded/created on startup
enableStatistics
boolean
Sets whether or not the Broker's services enable statistics or not.
jmsBridgeConnectors
(org.apache.activemq.network.jms.JmsConnector)*
keepDurableSubsActive
boolean
managementContext
org.apache.activemq.broker.jmx.ManagementContext
masterConnectorURI
java.lang.String
messageAuthorizationPolicy
org.apache.activemq.security.MessageAuthorizationPolicy
Sets the policy used to decide if the current connection is authorized to consume a given message
networkConnectorURIs
(java.lang.String)*
networkConnectors
(org.apache.activemq.network.NetworkConnector)*
Sets the network connectors which this broker will use to connect to other brokers in a federated network
persistenceAdapter
org.apache.activemq.store.PersistenceAdapter
Sets the persistence adaptor implementation to use for this broker
persistenceFactory
org.apache.activemq.store.PersistenceAdapterFactory
persistenceTaskRunnerFactory
org.apache.activemq.thread.TaskRunnerFactory
persistenceThreadPriority
int
persistent
boolean
Sets whether or not persistence is enabled or disabled.
plugins
(org.apache.activemq.broker.BrokerPlugin)*
Sets a number of broker plugins to install such as for security authentication or authorization
populateJMSXUserID
boolean
Sets whether or not the broker should populate the JMSXUserID header.
producerSystemUsage
org.apache.activemq.usage.SystemUsage
proxyConnectors
(java.lang.Object)*
Sets the network connectors which this broker will use to connect to other brokers in a federated network
services
(org.apache.activemq.Service)*
Sets the services associated with this broker such as a {@link MasterConnector}
shutdownOnMasterFailure
boolean
start
boolean
Sets whether or not the broker is started along with the ApplicationContext it is defined within. Normally you would want the broker to start up along with the ApplicationContext but sometimes when working with JUnit tests you may wish to start and stop the broker explicitly yourself.
supportFailOver
boolean
systemUsage
org.apache.activemq.usage.SystemUsage
taskRunnerFactory
org.apache.activemq.thread.TaskRunnerFactory
tempDataStore
org.apache.activemq.kaha.Store
tmpDataDirectory
java.io.File
transportConnectorURIs
(java.lang.String)*
transportConnectors
(org.apache.activemq.broker.TransportConnector)*
Sets the transport connectors which this broker will listen on for new clients
useJmx
boolean
Sets whether or not the Broker's services should be exposed into JMX or not.
useLocalHostBrokerName
boolean
useLoggingForShutdownErrors
boolean
Sets whether or not we should use commons-logging when reporting errors when shutting down the broker
useMirroredQueues
boolean
Sets whether or not Mirrored Queues should be supported by default if they have not been explicitly configured.
useShutdownHook
boolean
Sets whether or not we should use a shutdown handler to close down the broker cleanly if the JVM is terminated. It is recommended you leave this enabled.
useVirtualTopics
boolean
Sets whether or not Virtual Topics should be supported by default if they have not been explicitly configured.
vmConnectorURI
java.net.URI
The
This JDBCAdapter inserts and extracts BLOB data using the setBytes()/getBytes() operations. The databases/JDBC drivers that use this adapter are:
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
An agent which listens to commands on a JMS destination
Properties
Property Name
Type
Description
brokerUrl
java.lang.String
commandDestination
connection
javax.jms.Connection
connectionFactory
The
A demand forwarding bridge which works with multicast style transports where a single Transport could be communicating with multiple remote brokers
Properties
Property Name
Type
Description
configuration
org.apache.activemq.network.NetworkBridgeConfiguration
createdByDuplex
boolean
durableDestinations
(org.apache.activemq.command.ActiveMQDestination)*
dynamicallyIncludedDestinations
(org.apache.activemq.command.ActiveMQDestination)*
excludedDestinations
(org.apache.activemq.command.ActiveMQDestination)*
localBroker
org.apache.activemq.transport.Transport
networkBridgeListener
org.apache.activemq.network.NetworkBridgeListener
remoteBroker
org.apache.activemq.transport.Transport
staticallyIncludedDestinations
(org.apache.activemq.command.ActiveMQDestination)*
The
Represents a virtual queue which forwards to a number of other destinations.
Properties
Property Name
Type
Description
copyMessage
boolean
Sets whether a copy of the message will be sent to each destination. Defaults to true so that the forward destination is set as the destination of the message
forwardOnly
boolean
Sets if the virtual destination is forward only (and so there is no physical queue to match the virtual queue) or if there is also a physical queue with the same name).
forwardTo
(java.lang.Object)*
Sets the list of destinations to forward to
name
java.lang.String
Sets the name of this composite destination
The
Represents a virtual topic which forwards to a number of other destinations.
Properties
Property Name
Type
Description
copyMessage
boolean
Sets whether a copy of the message will be sent to each destination. Defaults to true so that the forward destination is set as the destination of the message
forwardOnly
boolean
Sets if the virtual destination is forward only (and so there is no physical queue to match the virtual queue) or if there is also a physical queue with the same name).
forwardTo
(java.lang.Object)*
Sets the list of destinations to forward to
name
java.lang.String
Sets the name of this composite destination
The
A DOT file creator plugin which creates a DOT file showing the current connections
Properties
Property Name
Type
Description
file
java.lang.String
Sets the destination file name to create the destination diagram
The
A Spring enhanced connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
Properties
Property Name
Type
Description
alwaysSessionAsync
boolean
If this flag is set then a separate thread is not used for dispatching messages for each Session in the Connection. However, a separate thread is always used if there is more than one session, or the session isn't in auto acknowledge or duplicates ok mode
alwaysSyncSend
boolean
Set true if always require messages to be sync sent
beanName
java.lang.String
blobTransferPolicy
org.apache.activemq.blob.BlobTransferPolicy
Sets the policy used to describe how out-of-band BLOBs (Binary Large OBjects) are transferred from producers to brokers to consumers
brokerURL
java.lang.String
Sets the connection URL used to connect to the ActiveMQ broker.
clientID
java.lang.String
Sets the JMS clientID to use for the created connection. Note that this can only be used by one connection at once so generally its a better idea to set the clientID on a Connection
clientIDPrefix
java.lang.String
Sets the prefix used by autogenerated JMS Client ID values which are used if the JMS client does not explicitly specify on.
clientIdGenerator
org.apache.activemq.util.IdGenerator
closeTimeout
int
Sets the timeout before a close is considered complete. Normally a close() on a connection waits for confirmation from the broker; this allows that operation to timeout to save the client hanging if there is no broker
copyMessageOnSend
boolean
Should a JMS message be copied to a new JMS Message object as part of the send() method in JMS. This is enabled by default to be compliant with the JMS specification. You can disable it if you do not mutate JMS messages after they are sent for a performance boost
disableTimeStampsByDefault
boolean
Sets whether or not timestamps on messages should be disabled or not. If you disable them it adds a small performance boost.
dispatchAsync
boolean
Enables or disables the default setting of whether or not consumers have their messages dispatched synchronously or asynchronously by the broker. For non-durable topics for example we typically dispatch synchronously by default to minimize context switches which boost performance. However sometimes its better to go slower to ensure that a single blocked consumer socket does not block delivery to other consumers.
exclusiveConsumer
boolean
Enables or disables whether or not queue consumers should be exclusive or not for example to preserve ordering when not using Message Groups
nestedMapAndListEnabled
boolean
Enables/disables whether or not Message properties and MapMessage entries support Nested Structures of Map and List objects
objectMessageSerializationDefered
boolean
When an object is set on an ObjectMessage, the JMS spec requires the object to be serialized by that set method. Enabling this flag causes the object to not get serialized. The object may subsequently get serialized if the message needs to be sent over a socket or stored to disk.
optimizeAcknowledge
boolean
optimizedMessageDispatch
boolean
If this flag is set then an larger prefetch limit is used - only applicable for durable topic subscribers.
password
java.lang.String
Sets the JMS password used for connections created from this factory
prefetchPolicy
org.apache.activemq.ActiveMQPrefetchPolicy
Sets the prefetch policy for consumers created by this connection.
producerWindowSize
int
properties
java.util.Properties
Get the properties from this instance for storing in JNDI
redeliveryPolicy
org.apache.activemq.RedeliveryPolicy
Sets the global redelivery policy to be used when a message is delivered but the session is rolled back
statsEnabled
boolean
transformer
org.apache.activemq.MessageTransformer
Sets the transformer used to transform messages before they are sent on to the JMS bus or when they are received from the bus but before they are delivered to the JMS client
transportListener
org.apache.activemq.transport.TransportListener
Allows a listener to be configured on the ConnectionFactory so that when this factory is used with frameworks which don't expose the Connection such as Spring JmsTemplate, you can still register a transport listener.
useAsyncSend
boolean
Forces the use of Async Sends which adds a massive performance boost; but means that the send() method will return immediately whether the message has been sent or not which could lead to message loss.
useBeanNameAsClientIdPrefix
boolean
useCompression
boolean
Enables the use of compression of the message bodies
useRetroactiveConsumer
boolean
Sets whether or not retroactive consumers are enabled. Retroactive consumers allow non-durable topic subscribers to receive old messages that were published before the non-durable subscriber started.
userName
java.lang.String
Sets the JMS userName used by connections created by this factory
warnAboutUnstartedConnectionTimeout
long
Enables the timeout from a connection creation to when a warning is generated if the connection is not properly started via {@link Connection#start()} and a message is received by a consumer. It is a very common gotcha to forget to start the connection so this option makes the default case to create a warning if the user forgets. To disable the warning just set the value to < 0 (say -1).
watchTopicAdvisories
boolean
The
This PendingMessageLimitStrategy is configured to a constant value for all subscriptions.
Properties
Property Name
Type
Description
limit
int
The
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
sub-classing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations.
The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations.
The databases/JDBC drivers that use this adapter are:
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
Identify if a limit has been reached
Properties
Property Name
Type
Description
limit
long
The
Forwards messages from the local broker to the remote broker based on demand.
Properties
Property Name
Type
Description
configuration
org.apache.activemq.network.NetworkBridgeConfiguration
createdByDuplex
boolean
durableDestinations
(org.apache.activemq.command.ActiveMQDestination)*
dynamicallyIncludedDestinations
(org.apache.activemq.command.ActiveMQDestination)*
excludedDestinations
(org.apache.activemq.command.ActiveMQDestination)*
localBroker
org.apache.activemq.transport.Transport
networkBridgeListener
org.apache.activemq.network.NetworkBridgeListener
remoteBroker
org.apache.activemq.transport.Transport
staticallyIncludedDestinations
(org.apache.activemq.command.ActiveMQDestination)*
The
A DOT file creator plugin which creates a DOT file showing the current topic & queue hierarchies.
Properties
Property Name
Type
Description
file
java.lang.String
Sets the destination file name to create the destination diagram
The
A default entry in a DestinationMap which holds a single value.
Properties
Property Name
Type
Description
destination
org.apache.activemq.command.ActiveMQDestination
queue
java.lang.String
A helper method to set the destination from a configuration file
topic
java.lang.String
A helper method to set the destination from a configuration file
value
java.lang.Object
The
Pending messages
The
Pending messages for durable subscribers
The
Pending
The
Represents a destination which is filtered using some predicate such as a selector so that messages are only dispatched to the destination if they match the filter.
Properties
Property Name
Type
Description
destination
org.apache.activemq.command.ActiveMQDestination
The destination to send messages to if they match the filter
filter
org.apache.activemq.filter.BooleanExpression
queue
java.lang.String
Sets the destination property to the given queue name
selector
java.lang.String
Sets the JMS selector used to filter messages before forwarding them to this destination
topic
java.lang.String
Sets the destination property to the given topic name
The
This implementation of {@link SubscriptionRecoveryPolicy} will keep a fixed count of last messages.
Properties
Property Name
Type
Description
maximumSize
int
Sets the maximum number of messages that this destination will hold around in RAM
The
This implementation of {@link SubscriptionRecoveryPolicy} will keep a fixed amount of memory available in RAM for message history which is evicted in time order.
Properties
Property Name
Type
Description
buffer
org.apache.activemq.memory.list.MessageList
maximumSize
int
Sets the maximum amount of RAM in bytes that this buffer can hold in RAM
useSharedBuffer
boolean
The
Forwards all messages from the local broker to the remote broker.
Properties
Property Name
Type
Description
clientId
java.lang.String
destinationFilter
java.lang.String
dispatchAsync
boolean
localBroker
org.apache.activemq.transport.Transport
networkBridgeFailedListener
org.apache.activemq.network.NetworkBridgeListener
prefetchSize
int
remoteBroker
org.apache.activemq.transport.Transport
The
Provides JDBCAdapter since that uses IMAGE datatype to hold binary data. The databases/JDBC drivers that use this adapter are:
- Sybase
- MS SQL
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
Create an Inbound Queue Bridge
Properties
Property Name
Type
Description
consumer
javax.jms.MessageConsumer
consumerConnection
javax.jms.QueueConnection
consumerQueue
doHandleReplyTo
boolean
inboundQueueName
java.lang.String
jmsConnector
org.apache.activemq.network.jms.JmsConnector
jmsMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
localQueueName
java.lang.String
maximumRetries
int
Sets the maximum number of retries if a send fails before closing the bridge
producerConnection
javax.jms.QueueConnection
producerQueue
selector
java.lang.String
The
Create an Inbound Topic Bridge
Properties
Property Name
Type
Description
consumer
javax.jms.MessageConsumer
consumerConnection
javax.jms.TopicConnection
consumerName
java.lang.String
consumerTopic
doHandleReplyTo
boolean
inboundTopicName
java.lang.String
jmsConnector
org.apache.activemq.network.jms.JmsConnector
jmsMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
localTopicName
java.lang.String
maximumRetries
int
Sets the maximum number of retries if a send fails before closing the bridge
producerConnection
javax.jms.TopicConnection
producerTopic
selector
java.lang.String
The
A {@link DeadLetterStrategy} where each destination has its own individual DLQ using the subject naming hierarchy.
Properties
Property Name
Type
Description
processExpired
boolean
processNonPersistent
boolean
queuePrefix
java.lang.String
Sets the prefix to use for all dead letter queues for queue messages
topicPrefix
java.lang.String
Sets the prefix to use for all dead letter queues for topic messages
useQueueForQueueMessages
boolean
Sets whether a queue or topic should be used for queue messages sent to a DLQ. The default is to use a Queue
useQueueForTopicMessages
boolean
Sets whether a queue or topic should be used for topic messages sent to a DLQ. The default is to use a Queue
The
JDBC Adapter for Informix database. Because Informix database restricts length of composite primary keys, length of container name field and subscription id field must be reduced to 150 characters. Therefore be sure not to use longer names for container name and subscription id than 150 characters.
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
Provides a JAAS based authentication plugin
Properties
Property Name
Type
Description
configuration
java.lang.String
Sets the JAAS configuration domain name used
discoverLoginConfig
boolean
Enables or disables the auto-discovery of the login.config file for JAAS to initialize itself. This flag is enabled by default such that if the java.security.auth.login.config system property is not defined then it is set to the location of the login.config file on the classpath.
The
Provides a JAAS based SSL certificate authentication plugin
Properties
Property Name
Type
Description
configuration
java.lang.String
Sets the JAAS configuration domain name used
discoverLoginConfig
boolean
Enables or disables the auto-discovery of the login.config file for JAAS to initialize itself. This flag is enabled by default such that if the java.security.auth.login.config system property is not defined then it is set to the location of the login.config file on the classpath.
The
A {@link PersistenceAdapter} implementation using JDBC for persistence storage. This persistence adapter will correctly remember prepared XA transactions, but it will not keep track of local transaction commits so that operations performed against the Message store are done as a single uow.
Properties
Property Name
Type
Description
adapter
org.apache.activemq.store.jdbc.JDBCAdapter
brokerName
java.lang.String
brokerService
org.apache.activemq.broker.BrokerService
cleanupPeriod
int
Sets the number of milliseconds until the database is attempted to be cleaned up for durable topics
createTablesOnStartup
boolean
Sets whether or not tables are created on startup
dataDirectory
java.lang.String
dataDirectoryFile
java.io.File
dataSource
javax.sql.DataSource
databaseLocker
org.apache.activemq.store.jdbc.DatabaseLocker
Sets the database locker strategy to use to lock the database on startup
directory
java.io.File
ds
javax.sql.DataSource
scheduledThreadPoolExecutor
java.util.concurrent.ScheduledThreadPoolExecutor
statements
org.apache.activemq.store.jdbc.Statements
usageManager
org.apache.activemq.usage.SystemUsage
useDatabaseLock
boolean
Sets whether or not an exclusive database lock should be used to enable JDBC Master/Slave. Enabled by default.
useExternalMessageReferences
boolean
wireFormat
org.apache.activemq.wireformat.WireFormat
The
A Bridge to other JMS Queue providers
Properties
Property Name
Type
Description
brokerService
org.apache.activemq.broker.BrokerService
One way to configure the local connection - this is called by The BrokerService when the Connector is embedded
inboundMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
inboundQueueBridges
(org.apache.activemq.network.jms.InboundQueueBridge)*
jndiLocalTemplate
org.springframework.jndi.JndiTemplate
jndiOutboundTemplate
org.springframework.jndi.JndiTemplate
localConnectionFactoryName
java.lang.String
localPassword
java.lang.String
localQueueConnection
javax.jms.QueueConnection
localQueueConnectionFactory
javax.jms.QueueConnectionFactory
localUsername
java.lang.String
name
java.lang.String
outboundMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
outboundPassword
java.lang.String
outboundQueueBridges
(org.apache.activemq.network.jms.OutboundQueueBridge)*
outboundQueueConnection
javax.jms.QueueConnection
outboundQueueConnectionFactory
javax.jms.QueueConnectionFactory
outboundQueueConnectionFactoryName
java.lang.String
outboundUsername
java.lang.String
replyToDestinationCacheSize
int
The
A Bridge to other JMS Topic providers
Properties
Property Name
Type
Description
brokerService
org.apache.activemq.broker.BrokerService
One way to configure the local connection - this is called by The BrokerService when the Connector is embedded
inboundMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
inboundTopicBridges
(org.apache.activemq.network.jms.InboundTopicBridge)*
jndiLocalTemplate
org.springframework.jndi.JndiTemplate
jndiOutboundTemplate
org.springframework.jndi.JndiTemplate
localConnectionFactoryName
java.lang.String
localPassword
java.lang.String
localTopicConnection
javax.jms.TopicConnection
localTopicConnectionFactory
javax.jms.TopicConnectionFactory
localUsername
java.lang.String
name
java.lang.String
outboundMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
outboundPassword
java.lang.String
outboundTopicBridges
(org.apache.activemq.network.jms.OutboundTopicBridge)*
outboundTopicConnection
javax.jms.TopicConnection
outboundTopicConnectionFactory
javax.jms.TopicConnectionFactory
outboundTopicConnectionFactoryName
java.lang.String
outboundUsername
java.lang.String
replyToDestinationCacheSize
int
The
An implementation of {@link PersistenceAdapter} designed for use with a {@link Journal} and then check pointing asynchronously on a timeout with some other long term persistent storage.
Properties
Property Name
Type
Description
brokerName
java.lang.String
directory
java.io.File
journal
org.apache.activeio.journal.Journal
longTermPersistence
org.apache.activemq.store.PersistenceAdapter
maxCheckpointMessageAddSize
int
maxCheckpointWorkers
int
taskRunnerFactory
org.apache.activemq.thread.TaskRunnerFactory
usageManager
org.apache.activemq.usage.SystemUsage
useExternalMessageReferences
boolean
The
Creates a default persistence model using the Journal and JDBC
Properties
Property Name
Type
Description
adapter
org.apache.activemq.store.jdbc.JDBCAdapter
createTablesOnStartup
boolean
Sets whether or not tables are created on startup
dataDirectory
java.lang.String
dataDirectoryFile
java.io.File
dataSource
javax.sql.DataSource
jdbcAdapter
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
journal
org.apache.activeio.journal.Journal
journalArchiveDirectory
java.io.File
journalLogFileSize
int
Sets the size of the journal log files
journalLogFiles
int
Sets the number of journal log files to use
journalThreadPriority
int
Sets the thread priority of the journal thread
statements
org.apache.activemq.store.jdbc.Statements
taskRunnerFactory
org.apache.activemq.thread.TaskRunnerFactory
useDatabaseLock
boolean
Sets whether or not an exclusive database lock should be used to enable JDBC Master/Slave. Enabled by default.
useJournal
boolean
Enables or disables the use of the journal. The default is to use the journal
useQuickJournal
boolean
Enables or disables the use of quick journal, which keeps messages in the journal and just stores a reference to the messages in JDBC. Defaults to false so that messages actually reside long term in the JDBC database.
The
Properties
Property Name
Type
Description
brokerName
java.lang.String
directory
java.io.File
maxDataFileLength
long
persistentIndex
boolean
size
java.util.concurrent.atomic.AtomicLong
usageManager
org.apache.activemq.usage.SystemUsage
The
An {@link AuthorizationMap} which uses LDAP
Properties
Property Name
Type
Description
adminAttribute
java.lang.String
adminBase
java.lang.String
authentication
java.lang.String
connectionPassword
java.lang.String
connectionProtocol
java.lang.String
connectionURL
java.lang.String
connectionUsername
java.lang.String
context
javax.naming.directory.DirContext
initialContextFactory
java.lang.String
options
java.util.Map
queueSearchMatchingFormat
java.text.MessageFormat
queueSearchSubtreeBool
boolean
readAttribute
java.lang.String
readBase
java.lang.String
topicSearchMatchingFormat
java.text.MessageFormat
topicSearchSubtreeBool
boolean
writeAttribute
java.lang.String
writeBase
java.lang.String
The
This implementation of {@link SubscriptionRecoveryPolicy} will only keep the last message.
The
class to create dynamic network connectors listed in an directory server using the LDAP v3 protocol as defined in RFC 2251, the entries listed in the directory server must implement the ipHost and ipService objectClasses as defined in RFC 2307.
Properties
Property Name
Type
Description
base
java.lang.String
sets the base LDAP dn used for lookup operations
bridgeTempDestinations
boolean
brokerName
java.lang.String
brokerService
org.apache.activemq.broker.BrokerService
conduitSubscriptions
boolean
connectionFilter
org.apache.activemq.network.ConnectionFilter
decreaseNetworkConsumerPriority
boolean
destinationFilter
java.lang.String
dispatchAsync
boolean
duplex
boolean
durableDestinations
(java.lang.Object)*
dynamicOnly
boolean
dynamicallyIncludedDestinations
(java.lang.Object)*
excludedDestinations
(java.lang.Object)*
localUri
java.net.URI
name
java.lang.String
networkTTL
int
objectName
javax.management.ObjectName
password
java.lang.String
sets the LDAP password for access credentials
prefetchSize
int
searchFilter
java.lang.String
sets the LDAP search filter as defined in RFC 2254
searchScope
java.lang.String
sets the LDAP search scope
staticallyIncludedDestinations
(java.lang.Object)*
uri
java.net.URI
sets the LDAP server URI
user
java.lang.String
sets the LDAP user for access credentials
userName
java.lang.String
The
A simple Broker interceptor which allows you to enable/disable logging.
Properties
Property Name
Type
Description
ackLog
org.apache.commons.logging.Log
adminConnectionContext
org.apache.activemq.broker.ConnectionContext
log
org.apache.commons.logging.Log
next
org.apache.activemq.broker.Broker
sendLog
org.apache.commons.logging.Log
The
A Flow provides different dispatch policies within the NMR
Properties
Property Name
Type
Description
MBeanServer
javax.management.MBeanServer
Get the MBeanServer
connectorPath
java.lang.String
connectorPort
int
createConnector
boolean
createMBeanServer
boolean
findTigerMbeanServer
boolean
Enables/disables the searching for the Java 5 platform MBeanServer
jmxDomainName
java.lang.String
rmiServerPort
int
server
javax.management.MBeanServer
useMBeanServer
boolean
The
Connects a Slave Broker to a Master when using Master Slave for High Availability of messages.
Properties
Property Name
Type
Description
brokerService
org.apache.activemq.broker.BrokerService
localURI
java.net.URI
password
java.lang.String
remoteURI
java.net.URI
remoteUri
java.lang.String
userName
java.lang.String
The
Properties
Property Name
Type
Description
brokerName
java.lang.String
directory
java.io.File
usageManager
org.apache.activemq.usage.SystemUsage
useExternalMessageReferences
boolean
The
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
Properties
Property Name
Type
Description
limit
long
Sets the memory limit in bytes. Setting the limit in bytes will set the usagePortion to 0 since the UsageManager is not going to be portion based off the parent. When set using XBean, you can use values such as: "20 mb", "1024 kb", or "1 gb"
limiter
org.apache.activemq.usage.UsageCapacity
name
java.lang.String
parent
T
percentUsage
int
percentUsageMinDelta
int
Sets the minimum number of percentage points the usage has to change before a UsageListener event is fired by the manager.
pollingTime
int
portion
float
usage
long
usagePortion
float
The
A factory to create instances of {@link SimpleMessageGroupMap} when implementing the Message Groups functionality.
Properties
Property Name
Type
Description
bucketCount
int
Sets the number of hash buckets to use for the message group functionality. This is only applicable to using message groups to parallelize processing of a queue while preserving order across an individual JMSXGroupID header value. This value sets the number of hash buckets that will be used (i.e. the maximum possible concurrency).
The
Creates Mirrored Queue using a prefix and postfix to define the topic name on which to mirror the queue to.
Properties
Property Name
Type
Description
brokerService
org.apache.activemq.broker.BrokerService
copyMessage
boolean
Sets whether a copy of the message will be sent to each destination. Defaults to true so that the forward destination is set as the destination of the message
postfix
java.lang.String
Sets any postix used to identify the queue consumers
prefix
java.lang.String
Sets the prefix wildcard used to identify the queue consumers for a given topic
The
A network connector which uses some kind of multicast-like transport that communicates with potentially many remote brokers over a single logical {@link Transport} instance such as when using multicast. This implementation does not depend on multicast at all; any other group based transport could be used.
Properties
Property Name
Type
Description
bridge
org.apache.activemq.network.DemandForwardingBridgeSupport
bridgeTempDestinations
boolean
brokerName
java.lang.String
brokerService
org.apache.activemq.broker.BrokerService
conduitSubscriptions
boolean
connectionFilter
org.apache.activemq.network.ConnectionFilter
decreaseNetworkConsumerPriority
boolean
destinationFilter
java.lang.String
dispatchAsync
boolean
duplex
boolean
durableDestinations
(java.lang.Object)*
dynamicOnly
boolean
dynamicallyIncludedDestinations
(java.lang.Object)*
excludedDestinations
(java.lang.Object)*
localTransport
org.apache.activemq.transport.Transport
localUri
java.net.URI
name
java.lang.String
networkTTL
int
objectName
javax.management.ObjectName
password
java.lang.String
prefetchSize
int
remoteTransport
org.apache.activemq.transport.Transport
Sets the remote transport implementation
remoteURI
java.net.URI
Sets the remote transport URI to some group transport like multicast://address:port
staticallyIncludedDestinations
(java.lang.Object)*
userName
java.lang.String
The
A Broker interceptor which allows you to trace all operations to a Multicast socket.
Properties
Property Name
Type
Description
address
java.net.SocketAddress
adminConnectionContext
org.apache.activemq.broker.ConnectionContext
broadcast
boolean
destination
java.net.URI
maxTraceDatagramSize
int
next
org.apache.activemq.broker.Broker
timeToLive
int
wireFormat
org.apache.activemq.wireformat.WireFormat
wireFormatFactory
org.apache.activemq.wireformat.WireFormatFactory
The
A network connector which uses a discovery agent to detect the remote brokers available and setup a connection to each available remote broker
Properties
Property Name
Type
Description
bridgeTempDestinations
boolean
brokerName
java.lang.String
brokerService
org.apache.activemq.broker.BrokerService
conduitSubscriptions
boolean
connectionFilter
org.apache.activemq.network.ConnectionFilter
decreaseNetworkConsumerPriority
boolean
destinationFilter
java.lang.String
discoveryAgent
org.apache.activemq.transport.discovery.DiscoveryAgent
discoveryURI
java.net.URI
dispatchAsync
boolean
duplex
boolean
durableDestinations
(java.lang.Object)*
dynamicOnly
boolean
dynamicallyIncludedDestinations
(java.lang.Object)*
excludedDestinations
(java.lang.Object)*
localUri
java.net.URI
name
java.lang.String
networkTTL
int
objectName
javax.management.ObjectName
password
java.lang.String
prefetchSize
int
staticallyIncludedDestinations
(java.lang.Object)*
uri
java.net.URI
userName
java.lang.String
The
This SubscriptionRecoveryPolicy disable recovery of messages.
The
An eviction strategy which evicts the oldest message first (which is the default).
Properties
Property Name
Type
Description
evictExpiredMessagesHighWatermark
int
Sets the high water mark on which we will eagerly evict expired messages from RAM
The
An eviction strategy which evicts the oldest message with the lowest priority first.
Properties
Property Name
Type
Description
evictExpiredMessagesHighWatermark
int
Sets the high water mark on which we will eagerly evict expired messages from RAM
The
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
Subclassing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations.
The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations.
The databases/JDBC drivers that use this adapter are:
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
Create an Outbound Queue Bridge
Properties
Property Name
Type
Description
consumer
javax.jms.MessageConsumer
consumerConnection
javax.jms.QueueConnection
consumerQueue
doHandleReplyTo
boolean
jmsConnector
org.apache.activemq.network.jms.JmsConnector
jmsMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
localQueueName
java.lang.String
maximumRetries
int
Sets the maximum number of retries if a send fails before closing the bridge
outboundQueueName
java.lang.String
producerConnection
javax.jms.QueueConnection
producerQueue
selector
java.lang.String
The
Create an Outbound Topic Bridge
Properties
Property Name
Type
Description
consumer
javax.jms.MessageConsumer
consumerConnection
javax.jms.TopicConnection
consumerName
java.lang.String
consumerTopic
doHandleReplyTo
boolean
jmsConnector
org.apache.activemq.network.jms.JmsConnector
jmsMessageConvertor
org.apache.activemq.network.jms.JmsMesageConvertor
localTopicName
java.lang.String
maximumRetries
int
Sets the maximum number of retries if a send fails before closing the bridge
outboundTopicName
java.lang.String
producerConnection
javax.jms.TopicConnection
producerTopic
selector
java.lang.String
The
Represents an entry in a {@link PolicyMap} for assigning policies to a specific destination or a hierarchical wildcard area of destinations.
Properties
Property Name
Type
Description
deadLetterStrategy
org.apache.activemq.broker.region.policy.DeadLetterStrategy
Sets the policy used to determine which dead letter queue destination should be used
destination
org.apache.activemq.command.ActiveMQDestination
dispatchPolicy
org.apache.activemq.broker.region.policy.DispatchPolicy
enableAudit
boolean
maxAuditDepth
int
maxProducersToAudit
int
maxQueueAuditDepth
int
memoryLimit
long
messageEvictionStrategy
org.apache.activemq.broker.region.policy.MessageEvictionStrategy
Sets the eviction strategy used to decide which message to evict when the slow consumer needs to discard messages
messageGroupMapFactory
org.apache.activemq.broker.region.group.MessageGroupMapFactory
Sets the factory used to create new instances of {MessageGroupMap} used to implement the Message Groups functionality.
optimizedDispatch
boolean
pendingDurableSubscriberPolicy
org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy
pendingMessageLimitStrategy
org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy
Sets the strategy to calculate the maximum number of messages that are allowed to be pending on consumers (in addition to their prefetch sizes). Once the limit is reached, non-durable topics can then start discarding old messages. This allows us to keep dispatching messages to slow consumers while not blocking fast consumers and discarding the messages oldest first.
pendingQueuePolicy
org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy
pendingSubscriberPolicy
org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy
producerFlowControl
boolean
queue
java.lang.String
A helper method to set the destination from a configuration file
sendAdvisoryIfNoConsumers
boolean
Sends an advisory message if a non-persistent message is sent and there are no active consumers
subscriptionRecoveryPolicy
org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy
topic
java.lang.String
A helper method to set the destination from a configuration file
The
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies.
Properties
Property Name
Type
Description
defaultEntry
org.apache.activemq.broker.region.policy.PolicyEntry
entries
(java.lang.Object)*
A helper method to allow the destination map to be populated from a dependency injection framework such as Spring
policyEntries
(java.lang.Object)*
Sets the individual entries on the policy map
The
Defines the prefetch message policies for different types of consumers
Properties
Property Name
Type
Description
all
int
durableTopicPrefetch
int
inputStreamPrefetch
int
maximumPendingMessageLimit
int
Sets how many messages a broker will keep around, above the prefetch limit, for non-durable topics before starting to discard older messages.
optimizeDurableTopicPrefetch
int
queueBrowserPrefetch
int
queuePrefetch
int
topicPrefetch
int
The
This PendingMessageLimitStrategy sets the maximum pending message limit value to be a multiplier of the prefetch limit of the subscription.
Properties
Property Name
Type
Description
multiplier
double
Sets the multiplier of the prefetch size which will be used to define the maximum number of pending messages for non-durable topics before messages are discarded.
The
Properties
Property Name
Type
Description
bind
java.net.URI
localUri
java.net.URI
name
java.lang.String
remote
java.net.URI
server
org.apache.activemq.transport.TransportServer
The
This implementation of {@link SubscriptionRecoveryPolicy} will perform a user specific query mechanism to load any messages they may have missed.
Properties
Property Name
Type
Description
query
org.apache.activemq.broker.region.policy.MessageQuery
Sets the query strategy to load initial messages
The
An ActiveMQ Queue
Properties
Property Name
Type
Description
compositeDestinations
(org.apache.activemq.command.ActiveMQDestination)*
name
java.lang.String
physicalName
java.lang.String
properties
java.util.Properties
Get the properties from this instance for storing in JNDI
The
Configuration options used to control how messages are re-delivered when they are rolled back.
Properties
Property Name
Type
Description
backOffMultiplier
short
collisionAvoidancePercent
short
initialRedeliveryDelay
long
maximumRedeliveries
int
useCollisionAvoidance
boolean
useExponentialBackOff
boolean
The
Simple dispatch policy that sends a message to every subscription that matches the message.
The
A default implementation of {@link DeadLetterStrategy} which uses a constant destination.
Properties
Property Name
Type
Description
deadLetterQueue
org.apache.activemq.command.ActiveMQDestination
processExpired
boolean
processNonPersistent
boolean
The
Provides a simple authentication plugin
Properties
Property Name
Type
Description
userGroups
java.util.Map
Sets the groups a user is in. The key is the user name and the value is a Set of groups
userPasswords
java.util.Map
Sets the map indexed by user name with the value the password
users
(java.lang.Object)*
Sets individual users for authentication
The
An AuthorizationMap which is configured with individual DestinationMaps for each operation.
Properties
Property Name
Type
Description
adminACLs
org.apache.activemq.filter.DestinationMap
readACLs
org.apache.activemq.filter.DestinationMap
tempDestinationAuthorizationEntry
org.apache.activemq.security.TempDestinationAuthorizationEntry
writeACLs
org.apache.activemq.filter.DestinationMap
The
Simple dispatch policy that sends a message to every subscription that matches the message.
The
Converts Message from one JMS to another
Properties
Property Name
Type
Description
connection
javax.jms.Connection
The
A factory to create instances of {@link SimpleMessageGroupMap} when implementing the Message Groups functionality.
The
Properties
Property Name
Type
Description
addMessageStatement
java.lang.String
binaryDataType
java.lang.String
containerNameDataType
java.lang.String
createDurableSubStatement
java.lang.String
createSchemaStatements
(java.lang.String)*
deleteOldMessagesStatement
java.lang.String
deleteSubscriptionStatement
java.lang.String
destinationMessageCountStatement
java.lang.String
dropSchemaStatements
(java.lang.String)*
durableSubAcksTableName
java.lang.String
durableSubscriberMessageCountStatement
java.lang.String
findAllDestinationsStatement
java.lang.String
findAllDurableSubMessagesStatement
java.lang.String
findAllDurableSubsStatement
java.lang.String
findAllMessagesStatement
java.lang.String
findDurableSubMessagesStatement
java.lang.String
findDurableSubStatement
java.lang.String
findLastSequenceIdInAcksStatement
java.lang.String
findLastSequenceIdInMsgsStatement
java.lang.String
findMessageSequenceIdStatement
java.lang.String
findMessageStatement
java.lang.String
findNextMessagesStatement
java.lang.String
lastAckedDurableSubscriberMessageStatement
java.lang.String
lockCreateStatement
java.lang.String
lockTableName
java.lang.String
lockUpdateStatement
java.lang.String
longDataType
java.lang.String
messageTableName
java.lang.String
msgIdDataType
java.lang.String
nextDurableSubscriberMessageStatement
java.lang.String
removeAllMessagesStatement
java.lang.String
removeAllSubscriptionsStatement
java.lang.String
removeMessageStatment
java.lang.String
sequenceDataType
java.lang.String
stringIdDataType
java.lang.String
tablePrefix
java.lang.String
updateLastAckOfDurableSubStatement
java.lang.String
updateMessageStatement
java.lang.String
useExternalMessageReferences
boolean
useLockCreateWhereClause
boolean
The
Pending messages
The
Pending messages for a durable
The
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
Properties
Property Name
Type
Description
limit
long
Sets the memory limit in bytes. Setting the limit in bytes will set the usagePortion to 0 since the UsageManager is not going to be portion based off the parent. When set using XBean, you can use values such as: "20 mb", "1024 kb", or "1 gb"
limiter
org.apache.activemq.usage.UsageCapacity
name
java.lang.String
parent
T
percentUsage
int
percentUsageMinDelta
int
Sets the minimum number of percentage points the usage has to change before a UsageListener event is fired by the manager.
pollingTime
int
store
org.apache.activemq.store.PersistenceAdapter
usagePortion
float
The
This JDBCAdapter inserts and extracts BLOB data using the setBinaryStream()/getBinaryStream() operations. The databases/JDBC drivers that use this adapter are:
- Axion
Properties
Property Name
Type
Description
batchStatments
boolean
statements
org.apache.activemq.store.jdbc.Statements
useExternalMessageReferences
boolean
The
Dispatch policy that causes every subscription to see messages in the same order.
The
Holder for Usage instances for memory, store and temp files Main use case is manage memory usage.
Properties
Property Name
Type
Description
adapter
org.apache.activemq.store.PersistenceAdapter
memoryUsage
org.apache.activemq.usage.MemoryUsage
name
java.lang.String
parent
org.apache.activemq.usage.SystemUsage
sendFailIfNoSpace
boolean
Sets whether or not a send() should fail if there is no space free. The default value is false which means to block the send() method until space becomes available
sendFailIfNoSpaceExplicitySet
boolean
storeUsage
org.apache.activemq.usage.StoreUsage
tempStore
org.apache.activemq.kaha.Store
tempUsage
org.apache.activemq.usage.TempUsage
The
Represents an entry in a {@link DefaultAuthorizationMap} for assigning different operations (read, write, admin) of user roles to a temporary destination
Properties
Property Name
Type
Description
admin
java.lang.String
adminACLs
(java.lang.Object)*
destination
org.apache.activemq.command.ActiveMQDestination
groupClass
java.lang.String
queue
java.lang.String
A helper method to set the destination from a configuration file
read
java.lang.String
readACLs
(java.lang.Object)*
topic
java.lang.String
A helper method to set the destination from a configuration file
write
java.lang.String
writeACLs
(java.lang.Object)*
The
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
Properties
Property Name
Type
Description
limit
long
Sets the memory limit in bytes. Setting the limit in bytes will set the usagePortion to 0 since the UsageManager is not going to be portion based off the parent. When set using XBean, you can use values such as: "20 mb", "1024 kb", or "1 gb"
limiter
org.apache.activemq.usage.UsageCapacity
name
java.lang.String
parent
T
percentUsage
int
percentUsageMinDelta
int
Sets the minimum number of percentage points the usage has to change before a UsageListener event is fired by the manager.
pollingTime
int
store
org.apache.activemq.kaha.Store
usagePortion
float
The
A Broker interceptor which updates a JMS Client's timestamp on the message with a broker timestamp. Useful when the clocks on client machines are known to not be correct and you can only trust the time set on the broker machines. Enabling this plugin will break JMS compliance since the timestamp that the producer sees on the messages after as send() will be different from the timestamp the consumer will observe when he receives the message. This plugin is not enabled in the default ActiveMQ configuration.
Properties
Property Name
Type
Description
adminConnectionContext
org.apache.activemq.broker.ConnectionContext
next
org.apache.activemq.broker.Broker
The
This implementation of {@link SubscriptionRecoveryPolicy} will keep a timed buffer of messages around in memory and use that to recover new subscriptions.
Properties
Property Name
Type
Description
recoverDuration
long
The
An ActiveMQ Topic
Properties
Property Name
Type
Description
compositeDestinations
(org.apache.activemq.command.ActiveMQDestination)*
name
java.lang.String
physicalName
java.lang.String
properties
java.util.Properties
Get the properties from this instance for storing in JNDI
The
Properties
Property Name
Type
Description
broker
org.apache.activemq.broker.Broker
brokerInfo
org.apache.activemq.command.BrokerInfo
brokerName
java.lang.String
connectUri
java.net.URI
disableAsyncDispatch
boolean
discoveryAgent
org.apache.activemq.transport.discovery.DiscoveryAgent
discoveryUri
java.net.URI
enableStatusMonitor
boolean
messageAuthorizationPolicy
org.apache.activemq.security.MessageAuthorizationPolicy
Sets the policy used to decide if the current connection is authorized to consume a given message
name
java.lang.String
server
org.apache.activemq.transport.TransportServer
taskRunnerFactory
org.apache.activemq.thread.TaskRunnerFactory
uri
java.net.URI
Sets the server transport URI to use if there is not a {@link TransportServer} configured via the {@link #setServer(TransportServer)} method. This value is used to lazy create a {@link TransportServer} instance
The
A Broker interceptor which allows you to trace all operations to a UDP socket.
Properties
Property Name
Type
Description
address
java.net.SocketAddress
adminConnectionContext
org.apache.activemq.broker.ConnectionContext
broadcast
boolean
destination
java.net.URI
maxTraceDatagramSize
int
next
org.apache.activemq.broker.Broker
wireFormat
org.apache.activemq.wireformat.WireFormat
wireFormatFactory
org.apache.activemq.wireformat.WireFormatFactory
The
Identify if a limit has been reached
Properties
Property Name
Type
Description
limit
long
The
Implements Virtual Topics.
Properties
Property Name
Type
Description
virtualDestinations
(org.apache.activemq.broker.region.virtual.VirtualDestination)*
The
Creates Virtual Topics using a prefix and postfix. The virtual destination creates a wildcard that is then used to look up all active queue subscriptions which match.
Properties
Property Name
Type
Description
name
java.lang.String
postfix
java.lang.String
Sets any postix used to identify the queue consumers
prefix
java.lang.String
Sets the prefix wildcard used to identify the queue consumers for a given topic
The
Pending messages held
The
Pending
The
Pending messages
The
A Spring enhanced XA connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
Properties
Property Name
Type
Description
alwaysSessionAsync
boolean
If this flag is set then a separate thread is not used for dispatching messages for each Session in the Connection. However, a separate thread is always used if there is more than one session, or the session isn't in auto acknowledge or duplicates ok mode
alwaysSyncSend
boolean
Set true if always require messages to be sync sent
beanName
java.lang.String
blobTransferPolicy
org.apache.activemq.blob.BlobTransferPolicy
Sets the policy used to describe how out-of-band BLOBs (Binary Large OBjects) are transferred from producers to brokers to consumers
brokerURL
java.lang.String
Sets the connection URL used to connect to the ActiveMQ broker.
clientID
java.lang.String
Sets the JMS clientID to use for the created connection. Note that this can only be used by one connection at once so generally its a better idea to set the clientID on a Connection
clientIDPrefix
java.lang.String
Sets the prefix used by autogenerated JMS Client ID values which are used if the JMS client does not explicitly specify on.
clientIdGenerator
org.apache.activemq.util.IdGenerator
closeTimeout
int
Sets the timeout before a close is considered complete. Normally a close() on a connection waits for confirmation from the broker; this allows that operation to timeout to save the client hanging if there is no broker
copyMessageOnSend
boolean
Should a JMS message be copied to a new JMS Message object as part of the send() method in JMS. This is enabled by default to be compliant with the JMS specification. You can disable it if you do not mutate JMS messages after they are sent for a performance boost
disableTimeStampsByDefault
boolean
Sets whether or not timestamps on messages should be disabled or not. If you disable them it adds a small performance boost.
dispatchAsync
boolean
Enables or disables the default setting of whether or not consumers have their messages dispatched synchronously or asynchronously by the broker. For non-durable topics for example we typically dispatch synchronously by default to minimize context switches which boost performance. However sometimes its better to go slower to ensure that a single blocked consumer socket does not block delivery to other consumers.
exclusiveConsumer
boolean
Enables or disables whether or not queue consumers should be exclusive or not for example to preserve ordering when not using Message Groups
nestedMapAndListEnabled
boolean
Enables/disables whether or not Message properties and MapMessage entries support Nested Structures of Map and List objects
objectMessageSerializationDefered
boolean
When an object is set on an ObjectMessage, the JMS spec requires the object to be serialized by that set method. Enabling this flag causes the object to not get serialized. The object may subsequently get serialized if the message needs to be sent over a socket or stored to disk.
optimizeAcknowledge
boolean
optimizedMessageDispatch
boolean
If this flag is set then an larger prefetch limit is used - only applicable for durable topic subscribers.
password
java.lang.String
Sets the JMS password used for connections created from this factory
prefetchPolicy
org.apache.activemq.ActiveMQPrefetchPolicy
Sets the prefetch policy for consumers created by this connection.
producerWindowSize
int
properties
java.util.Properties
Get the properties from this instance for storing in JNDI
redeliveryPolicy
org.apache.activemq.RedeliveryPolicy
Sets the global redelivery policy to be used when a message is delivered but the session is rolled back
statsEnabled
boolean
transformer
org.apache.activemq.MessageTransformer
Sets the transformer used to transform messages before they are sent on to the JMS bus or when they are received from the bus but before they are delivered to the JMS client
transportListener
org.apache.activemq.transport.TransportListener
Allows a listener to be configured on the ConnectionFactory so that when this factory is used with frameworks which don't expose the Connection such as Spring JmsTemplate, you can still register a transport listener.
useAsyncSend
boolean
Forces the use of Async Sends which adds a massive performance boost; but means that the send() method will return immediately whether the message has been sent or not which could lead to message loss.
useBeanNameAsClientIdPrefix
boolean
useCompression
boolean
Enables the use of compression of the message bodies
useRetroactiveConsumer
boolean
Sets whether or not retroactive consumers are enabled. Retroactive consumers allow non-durable topic subscribers to receive old messages that were published before the non-durable subscriber started.
userName
java.lang.String
Sets the JMS userName used by connections created by this factory
warnAboutUnstartedConnectionTimeout
long
Enables the timeout from a connection creation to when a warning is generated if the connection is not properly started via {@link Connection#start()} and a message is received by a consumer. It is a very common gotcha to forget to start the connection so this option makes the default case to create a warning if the user forgets. To disable the warning just set the value to < 0 (say -1).
watchTopicAdvisories
boolean
Element Index
An implementation of {@link PersistenceAdapter} designed for use with a {@link Journal} and then check pointing asynchronously on a timeout with some other long term persistent storage.
An implementation of {@link PersistenceAdapterFactory}
A helper object used to configure simple authentiaction plugin
Represents an entry in a {@link DefaultAuthorizationMap} for assigning different operations (read, write, admin) of user roles to a specific destination or a hierarchical wildcard area of destinations.
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies. Each entry in the map represents the authorization ACLs for each operation.
An authorization plugin where each operation on a destination is checked against an authorizationMap
Axion specific Adapter. Axion does not seem to support ALTER statements or sub-selects. This means: - We cannot auto upgrade the schema was we roll out new versions of ActiveMQ - We cannot delete durable sub messages that have be acknowledged by all consumers.
This JDBCAdapter inserts and extracts BLOB data using the getBlob()/setBlob() operations. This is a little more involved since to insert a blob you have to: 1: insert empty blob. 2: select the blob 3: finally update the blob with data value. The databases/JDBC drivers that use this adapter are:
An ActiveMQ Message Broker. It consists of a number of transport connectors, network connectors and a bunch of properties which can be used to configure the broker as its lazily created.
This JDBCAdapter inserts and extracts BLOB data using the setBytes()/getBytes() operations. The databases/JDBC drivers that use this adapter are:
An agent which listens to commands on a JMS destination
A demand forwarding bridge which works with multicast style transports where a single Transport could be communicating with multiple remote brokers
Represents a virtual queue which forwards to a number of other destinations.
Represents a virtual topic which forwards to a number of other destinations.
A DOT file creator plugin which creates a DOT file showing the current connections
A Spring enhanced connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
This PendingMessageLimitStrategy is configured to a constant value for all subscriptions.
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
sub-classing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations.
The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations.
The databases/JDBC drivers that use this adapter are:
Identify if a limit has been reached
Forwards messages from the local broker to the remote broker based on demand.
A DOT file creator plugin which creates a DOT file showing the current topic & queue hierarchies.
A default entry in a DestinationMap which holds a single value.
Pending messages
Pending messages for durable subscribers
Pending
Represents a destination which is filtered using some predicate such as a selector so that messages are only dispatched to the destination if they match the filter.
This implementation of {@link SubscriptionRecoveryPolicy} will keep a fixed count of last messages.
This implementation of {@link SubscriptionRecoveryPolicy} will keep a fixed amount of memory available in RAM for message history which is evicted in time order.
Forwards all messages from the local broker to the remote broker.
Provides JDBCAdapter since that uses IMAGE datatype to hold binary data. The databases/JDBC drivers that use this adapter are:
- Sybase
- MS SQL
Create an Inbound Queue Bridge
Create an Inbound Topic Bridge
A {@link DeadLetterStrategy} where each destination has its own individual DLQ using the subject naming hierarchy.
JDBC Adapter for Informix database. Because Informix database restricts length of composite primary keys, length of container name field and subscription id field must be reduced to 150 characters. Therefore be sure not to use longer names for container name and subscription id than 150 characters.
Provides a JAAS based authentication plugin
Provides a JAAS based SSL certificate authentication plugin
A {@link PersistenceAdapter} implementation using JDBC for persistence storage. This persistence adapter will correctly remember prepared XA transactions, but it will not keep track of local transaction commits so that operations performed against the Message store are done as a single uow.
A Bridge to other JMS Queue providers
A Bridge to other JMS Topic providers
An implementation of {@link PersistenceAdapter} designed for use with a {@link Journal} and then check pointing asynchronously on a timeout with some other long term persistent storage.
Creates a default persistence model using the Journal and JDBC
An {@link AuthorizationMap} which uses LDAP
This implementation of {@link SubscriptionRecoveryPolicy} will only keep the last message.
class to create dynamic network connectors listed in an directory server using the LDAP v3 protocol as defined in RFC 2251, the entries listed in the directory server must implement the ipHost and ipService objectClasses as defined in RFC 2307.
A simple Broker interceptor which allows you to enable/disable logging.
A Flow provides different dispatch policies within the NMR
Connects a Slave Broker to a Master when using Master Slave for High Availability of messages.
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
A factory to create instances of {@link SimpleMessageGroupMap} when implementing the Message Groups functionality.
Creates Mirrored Queue using a prefix and postfix to define the topic name on which to mirror the queue to.
A network connector which uses some kind of multicast-like transport that communicates with potentially many remote brokers over a single logical {@link Transport} instance such as when using multicast. This implementation does not depend on multicast at all; any other group based transport could be used.
A Broker interceptor which allows you to trace all operations to a Multicast socket.
A network connector which uses a discovery agent to detect the remote brokers available and setup a connection to each available remote broker
This SubscriptionRecoveryPolicy disable recovery of messages.
An eviction strategy which evicts the oldest message first (which is the default).
An eviction strategy which evicts the oldest message with the lowest priority first.
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
Subclassing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations.
The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations.
The databases/JDBC drivers that use this adapter are:
Create an Outbound Queue Bridge
Create an Outbound Topic Bridge
Represents an entry in a {@link PolicyMap} for assigning policies to a specific destination or a hierarchical wildcard area of destinations.
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies.
Defines the prefetch message policies for different types of consumers
This PendingMessageLimitStrategy sets the maximum pending message limit value to be a multiplier of the prefetch limit of the subscription.
This implementation of {@link SubscriptionRecoveryPolicy} will perform a user specific query mechanism to load any messages they may have missed.
An ActiveMQ Queue
Configuration options used to control how messages are re-delivered when they are rolled back.
Simple dispatch policy that sends a message to every subscription that matches the message.
A default implementation of {@link DeadLetterStrategy} which uses a constant destination.
Provides a simple authentication plugin
An AuthorizationMap which is configured with individual DestinationMaps for each operation.
Simple dispatch policy that sends a message to every subscription that matches the message.
Converts Message from one JMS to another
A factory to create instances of {@link SimpleMessageGroupMap} when implementing the Message Groups functionality.
Pending messages
Pending messages for a durable
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
This JDBCAdapter inserts and extracts BLOB data using the setBinaryStream()/getBinaryStream() operations. The databases/JDBC drivers that use this adapter are:
- Axion
Dispatch policy that causes every subscription to see messages in the same order.
Holder for Usage instances for memory, store and temp files Main use case is manage memory usage.
Represents an entry in a {@link DefaultAuthorizationMap} for assigning different operations (read, write, admin) of user roles to a temporary destination
Used to keep track of how much of something is being used so that a productive working set usage can be controlled. Main use case is manage memory usage.
A Broker interceptor which updates a JMS Client's timestamp on the message with a broker timestamp. Useful when the clocks on client machines are known to not be correct and you can only trust the time set on the broker machines. Enabling this plugin will break JMS compliance since the timestamp that the producer sees on the messages after as send() will be different from the timestamp the consumer will observe when he receives the message. This plugin is not enabled in the default ActiveMQ configuration.
This implementation of {@link SubscriptionRecoveryPolicy} will keep a timed buffer of messages around in memory and use that to recover new subscriptions.
An ActiveMQ Topic
A Broker interceptor which allows you to trace all operations to a UDP socket.
Identify if a limit has been reached
Implements Virtual Topics.
Creates Virtual Topics using a prefix and postfix. The virtual destination creates a wildcard that is then used to look up all active queue subscriptions which match.
Pending messages held
Pending
Pending messages
A Spring enhanced XA connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.